package com.example.kafka.service;

/**
 * @author jiyupeng
 */
public interface KafkaService {

	void sendMessageInAsyncWay(String message);

	void sendMessageInSyncWay(String message);

	void sendMessageInTransaction(String message);

	void createTopic(String topic);

	void sendMessageInTransactionAnno(String message) throws Exception;
}
